package com.shujia;

import org.apache.hadoop.hive.ql.exec.UDF;

// 自定义UDF
public class HiveUDF extends UDF {
    // 函数名必须是evaluate
    // arg1 表示传进来的数据
    // 实现了 传入 hadoop => #hadoop$
    public String evaluate(String arg1) {
        return "#" + arg1 + "$";
    }
}
